package com.wangan.wanganpush.services;

import com.wangan.wanganpush.dao.ChatDao;
import com.wangan.wanganpush.model.Chat;
import com.wangan.wanganpush.model.UserLogin;
import org.springframework.beans.factory.annotation.Autowired;

import java.sql.Timestamp;
import java.util.List;

public class ChatImpl {
    @Autowired
    ChatDao chatDao;

    public Boolean userLoginPush() {
        try {
            //查询出需要推送的数据
            List<Chat> li = chatDao.findAllByFlag(0);

            //调用推送方法
            if (li != null && li.size() > 0) {
                //把数据送往xml转zip包的流程
                //todo

            }
            System.out.println(li.size());

            //更改数据库flag字段为1已经发送
            if (li != null && li.size() > 0) {
                for (int i = 0; i < li.size(); i++) {
                    li.get(i).setFlag(1);
                    //时间更新
                    li.get(i).setUpdateTime(new Timestamp(System.currentTimeMillis()));
                }
                //更新数据
                chatDao.save(li);
                //提交事务
                chatDao.flush();
            }

            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }


    }
}
